feat(changefeed): add initial_scan to ydb_table_changefeed#62
Open
kprokopenko wants to merge 1 commit into
Open
feat(changefeed): add initial_scan to ydb_table_changefeed#62kprokopenko wants to merge 1 commit into
kprokopenko wants to merge 1 commit into
Conversation
Add optional initial_scan (default false, ForceNew) to match YDB CDC ALTER TABLE ADD CHANGEFEED WITH (INITIAL_SCAN = TRUE). DescribeTable does not return this flag; refresh keeps the configured value in state to avoid spurious drift. Fixes #52 Made-with: Cursor
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Adds optional
initial_scanto theydb_table_changefeedresource so changefeeds can request an initial table snapshot at creation time, aligned with YDB CDC / ALTER TABLE changefeed.Behaviour
initial_scanis optional, defaults tofalse, and is ForceNew (YDB only runs the initial scan when the changefeed is created).true, the provider emitsINITIAL_SCAN = TRUEin theADD CHANGEFEED ... WITH (...)scheme query.DescribeTabledoes not expose this flag on the changefeed description; on read/refresh we persist the configured value from state to avoid spurious drift.Tests
PrepareCreateRequestwithinitial_scanon/off.Closes #52
Made with Cursor